//package com.zlcx.tz.live.queue;
//
//import com.alibaba.fastjson.JSON;
//import com.zlcx.tz.live.vo.RecordVideoMessage;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.lang.StringEscapeUtils;
//import org.springframework.data.redis.connection.Message;
//import org.springframework.data.redis.connection.MessageListener;
//import org.springframework.stereotype.Component;
//
///**
// * <p>视频合成结束监听</p>
// * <PRE>
// * <BR>    修改记录
// * <BR>-----------------------------------------------
// * <BR>    修改日期         修改人          修改内容
// * </PRE>
// *
// * @author zl
// * @version 1.0
// * @date Created in 2019/6/18 13:28
// * @copyright: Copyright (c) founders
// */
//@Slf4j
//@Component
//public class SubscribeRecordVideoFinishListener implements MessageListener {
//
//    @Override
//    public void onMessage(Message message, byte[] pattern) {
//
//        String body = new String(message.getBody());
//        body = StringEscapeUtils.unescapeJavaScript(body);
//        body = body.startsWith("\"")?body.substring(1):body;
//        body = body.endsWith("\"")?body.substring(0,body.length()-1):body;
//        log.info("视频合成结束消息,message={}", body);
//
//        try {
//            RecordVideoMessage videoMessage = JSON.parseObject(body,RecordVideoMessage.class);
//
//
//
//
//        }catch (Exception e){
//            log.error("视频合成结束消息处理失败，message={},e={}",message,e);
//        }
//
//    }
//
//}
